9c4c63ccae2dee3cdead7d2e83928e26d8a84a48,contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java,CassandraStorage,columnToTuple,#ByteBuffer#IColumn#CfDef#,141
Before Change
if (marshallers.get(1) instanceof BytesType)
pair.set(1, new DataByteArray(ByteBufferUtil.getArray(col.value())));
else
pair.set(1, marshallers.get(1).compose(col.value()));
else
pair.set(1, validators.get(name).compose(col.value()));
return pair;
After Change
private Tuple columnToTuple(ByteBuffer name, IColumn col, CfDef cfDef) throws IOException
{
Tuple pair = TupleFactory.getInstance().newTuple(2);
List<AbstractType> marshallers = getDefaultMarshallers(cfDef);
Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef);
setTupleValue(pair, 0, marshallers.get(0).compose(name));
if (col instanceof Column)
{
// standard
if (validators.get(name) == null)
setTupleValue(pair, 1, marshallers.get(1).compose(col.value()));
else
setTupleValue(pair, 1, validators.get(name).compose(col.value()));
return pair;